package cn.terminus.service.customer.analysis;

import cn.terminus.client.customer.contractinfo.param.RentContractNewParam;
import cn.terminus.client.customer.custompurposeroom.param.CustomPurposeRoomNewParam;
import cn.terminus.result.common.context.TerminusCallContext;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;

import javax.annotation.Resource;
import java.util.List;

/**
 * @author leslie.zhang
 * @date 2021/9/1 2:39 下午
 */
@Component
public class AnalysisHandler {

    @Resource
    private KafkaTemplate<String, String> kafkaTemplate;

//    @Value("${topicName_channelAnalysis_topic}")
    private String topicName_channelAnalysis;
//    @Value("${topicKeyName_channelAnalysis_topic}")
    private String topicKeyName_channelAnalysis;


    public void contractAddPush(RentContractNewParam param, TerminusCallContext context) {
        List<CustomPurposeRoomNewParam> purposeRoomNewList = param.getPurposeRoomNewList();
        if (!CollectionUtils.isEmpty(purposeRoomNewList)) {
           /* sendMsgWithChannel();
            sendMsgWithContract();*/

        }
    }
}
